package com.chj.consumers;

import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class KafkaConsumer {

//    @KafkaListener(topics = {"test-demo"}, groupId = "consumer-group-01")
//    public void TestDemoConsumer1(String message){
//        log.info("GroupId = consumer-group-01, TestDemoConsumer1 ---> {}", message);
//    }
//
//    @KafkaListener(topics = {"test-demo"}, groupId = "consumer-group-02")
//    public void TestDemoConsumer2(String message){
//        log.info("GroupId = consumer-group-02, TestDemoConsumer2 ---> {}", message);
//    }


}
